package com.chenjj.bigdata.hbase.bulkload;

public class BulkLoadRunner {
    public static void main(String[] args) throws Exception {
        BulkLoadServie bs = new BulkLoadServie();

        args = new String[] {"deposit1",  //hbase表名
                "/tmp/hbasedata/deposit.txt", //数据文件目录
                "/tmp/hfile/deposit.hfile",  //hfile生成目录
                "com.chenjj.bigdata.hbase.bulkload.BulkLoadMapper", //mapperClass
                "dcnode1", //zkHost
                "2181"}; //zkPort

        int code = bs.doBulkLoad(args);
        System.exit(code);
    }
}
